package com.flute.haflute.agent.topo;

import org.apache.mina.core.session.IoSession;

import com.flute.haflute.net.messaging.Message;

/**
 * 集群消息处理器，监听消息然后处理
 */
public interface ClusterMessageListener {

	/**
	 * 异步的处理该消息<br>
	 * <b>注意：</b>必须异步处理，以免阻塞后续消息的接受和处理。
	 * 
	 * @param message
	 *            消息
	 * @param session
	 *            收到此消息的Session
	 */
	public void asyncHandle(Message message, IoSession session);

}
